package com.alibaba.datax.example.streamreader;

import com.alibaba.datax.example.ExampleContainer;
import com.alibaba.datax.example.util.PathUtil;
import org.junit.Test;

/**
 * @Description
 * @Author zhangsong
 * @Date 2024/4/3
 **/
public class MysqlToStream {
    @Test
    public void testMsql2StreamWriter() {
        String path = "/mysql2stream.json";
        String jobPath = PathUtil.getAbsolutePathFromClassPath(path);
        ExampleContainer.start(jobPath);
    }
}
